Creating Stream processing application in Kafka